b011752e150967db5241641b2592422a51f8ce18,src/java/org/apache/cassandra/db/CompactionManager.java,CompactionManager,doAntiCompaction,#ColumnFamilyStore#Collection#Collection#InetAddress#,395
Before Change
results.add(writer.closeAndOpenReader(getMaxDataAge(sstables)));
String format = "AntiCompacted to %s. %d/%d bytes for %d keys. Time: %dms.";
long dTime = System.currentTimeMillis() - startTime;
logger.info(String.format(format, writer.getFilename(), SSTable.getTotalBytes(sstables), results.get(0).length(), totalkeysWritten, dTime));
}
return results;
After Change
String format = "AntiCompacted to %s. %,d to %,d (~%d%% of original) bytes for %,d keys. Time: %,dms.";
long dTime = System.currentTimeMillis() - startTime;
long startsize = SSTable.getTotalBytes(sstables);
long endsize = results.get(0).length();
double ratio = (double)endsize / (double)startsize;
logger.info(String.format(format, writer.getFilename(), startsize, endsize, (int)(ratio*100), totalkeysWritten, dTime));
}
return results;